package com.example.rabbitmq.comsumer.topic;/**
 * ClassName: TopicReceiverA <br/> Description: <br/> date: 2022/1/24 11:05<br/>
 *
 * @author chenzhian<br />
 * @version
 */

import com.example.common.config.RabbitMQConfig;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @Author: chenzhian
 * @Date: 2022/1/24 11:05
 * @Description:
 */
@Component
@RabbitListener(queues = RabbitMQConfig.RABBITMQ_TOPIC_QUEUE_A)
public class TopicReceiverA {

  @RabbitHandler
  public void process(String msg){
    System.out.println("Topic ReceiverA: " + msg);
  }
}